package com.taobao.txc.resourcemanager.d;

import com.taobao.txc.a.b.n;
import com.taobao.txc.common.LoggerInit;
import com.taobao.txc.common.LoggerWrap;
import com.taobao.txc.common.TxcContext;
import com.taobao.txc.common.b.c;
import com.taobao.txc.common.c.d;
import com.taobao.txc.common.c.e;
import com.taobao.txc.resourcemanager.i;
import com.taobao.txc.resourcemanager.k;

public class a
  extends k
{
  private static final LoggerWrap a = LoggerInit.logger;
  private b b;
  
  public static a i()
  {
    return (a)i.a("rt");
  }
  
  public void a(com.taobao.txc.a.a.b paramb)
  {
    this.b = ((b)paramb);
    super.a(paramb);
  }
  
  public e a(com.taobao.txc.resourcemanager.b.a.b paramb, String paramString)
  {
    return a(paramb, paramString, 10);
  }
  
  public e a(com.taobao.txc.resourcemanager.b.a.b paramb, String paramString, int paramInt)
  {
    d locald = new d();
    e locale = null;
    locald.a(paramb.b());
    locald.b(paramString);
    long l = TxcContext.h();
    if (l < 0L) {
      return null;
    }
    locald.a(l);
    locald.a((byte)com.taobao.txc.common.a.c.a());
    int i = 0;
    while (i < paramInt) {
      try
      {
        n localn = this.b.h();
        com.taobao.txc.resourcemanager.b.b.a(paramb, localn.b);
        locale = (e)this.b.a(localn.b, localn.a, locald, 30000L);
        return locale;
      }
      catch (Exception localException)
      {
        a.a(com.taobao.txc.common.b.b.S.bd, localException.getMessage(), localException);
      }
    }
    return locale;
  }
  
  public void a(String paramString1, long paramLong, String paramString2)
  {
    throw new c("RtResourceManager unsupport queryReadLocks");
  }
}


/* Location:           C:\Users\ibm\Downloads\txc-yun-sample (1)\txc-yun-sample\lib\txc-client-2.0.72.jar
 * Qualified Name:     com.taobao.txc.resourcemanager.d.a
 * JD-Core Version:    0.7.0.1
 */